ea76ac2badcda417ad1ba9fb9955fca5438c8a3a,src/org/jgroups/protocols/UDP.java,UcastReceiver,run,#,863

Before Change



            final DatagramPacket packet=new DatagramPacket(receive_buf, receive_buf.length);

            while(running && thread != null && sock != null) {
                try {
                    sock.receive(packet);
                    len=packet.getLength();
                    if(len > receive_buf.length) {
                        if(log.isErrorEnabled())
                            log.error("size of the received packet (" + len + ") is bigger than allocated buffer (" +
                                      receive_buf.length + "): will not be able to handle packet. " +
                                      "Use the FRAG2 protocol and make its frag_size lower than " + receive_buf.length);
                    }

                    sender_addr=packet.getAddress();
                    sender_port=packet.getPort();
                    offset=packet.getOffset();
                    sender=new IpAddress(sender_addr, sender_port);

                    receive(local_addr, sender, receive_buf, offset, len);
                }
                catch(SocketException sock_ex) {
                    if(log.isDebugEnabled()) log.debug("unicast receiver socket is closed, exception=" + sock_ex);

After Change


        }
               
        public void run() {
            final byte receive_buf[]=new byte[65535];
            final DatagramPacket packet=new DatagramPacket(receive_buf, receive_buf.length);

            while(running) {
                try {
                    socket.receive(packet);
                    int len=packet.getLength();
                    if(len > receive_buf.length) {
                        if(log.isErrorEnabled())
                            log.error("size of the received packet (" + len
                                      + ") is bigger than "
                                      + "allocated buffer ("
                                      + receive_buf.length
                                      + "): will not be able to handle packet. "
                                      + "Use the FRAG2 protocol and make its frag_size lower than "
                                      + receive_buf.length);
                    }
                    receive(dest,
                            new IpAddress(packet.getAddress(), packet.getPort()),
                            receive_buf,
                            packet.getOffset(),
                            len);
                }
                catch(IOException sock_ex) {
                    boolean socketConnected = (socket != null && socket.isConnected());